package com.ayz.gateway.core.session.executor;


import com.ayz.gateway.core.datasource.RpcStatement;

/**
 * @ClassName Executor
 * @Description TODO: 执行器执行一个具体的RPC执行计划(RpcStatement),并负责将GatewayResult写入响应回调函数,发送给前端
 * @Author 快乐的星球
 * @Date 2023/5/10 18:03
 * @Version 1.0
 **/
public interface Executor {
    /**
     * 执行器的执行方法
     * @param rpcStatement
     */
    void execute(RpcStatement rpcStatement);

//    /**
//     * 异步执行RPC计划
//     * @param rpcStatement
//     * @param executor 需要传入一个线程池
//     */
//    void execute(RpcStatement rpcStatement, java.util.concurrent.Executor executor);
}
